/*
 * Copyright (c) 2020 Carnegie Lee
 * All rights reserved
 */
package com.geekc.kafka.constant;

/**
 * Kafka常量
 * @author Carnegie Lee
 */
public class KafkaConst {
    /** Kafka请求主题名称 - 非Replying模式 */
    public final static String KAFKA_TARGET_TOPIC_SIMPLE = "topic.simple.demo";
    /** Kafka请求主题名称 - Replying模式 */
    public final static String KAFKA_TARGET_TOPIC_REPLYING = "topic.replying.demo";
    /** Kafka响应主题名称 */
    public final static String KAFKA_REPLYING_TOPIC = "topic.reply";
    /** Kafka消费者群组名称 - 非Replying模式 */
    public final static String KAFKA_CONSUMER_GROUP_SIMPLE = "consumer-simple-group";
    /** Kafka消费者群组名称 - Replying模式 */
    public final static String KAFKA_CONSUMER_GROUP_REPLYING = "consumer-replying-group";
    /** Kafka响应群组 */
    public final static String KAFKA_REPLYING_GROUP = "reply-group";
    /** Kafka分区数 */
    public final static String[] KAFKA_PARTITIONER = {"0"};
    /** Kafka消费者并发数量 */
    public final static String KAFKA_CONSUMER_CONCURRENCY = "1";
    /** Kafka消费错误处理器 */
    public final static String KAFKA_CONSUMER_ERROR_HANDLER = "kafkaErrorHandler";
}
